SynchronizeWitness class¶

Summary¶

View source

Observer that serializes notifications behind a gate so downstream operators always observe the single-threaded OnNext* then OnError|OnCompleted grammar they depend on, even when the upstream source delivers concurrently. Stateful sinks (counting, distinct, buffering) rely on that grammar; placing one of these ahead of them is the supported way to consume a non-conformant source.

classDiagram
class SynchronizeWitness~T~
class IObserver~T~ {
    <>
}
IObserver~T~ <|.. SynchronizeWitness~T~
class IDisposable {
    <>
}
IDisposable <|.. SynchronizeWitness~T~

Implements: IObserver, IDisposable

Constructors¶

Methods¶